//package org.example.job;
//
//import com.dangdang.ddframe.job.api.dataflow.DataflowJob;
//import com.dangdang.ddframe.job.config.JobCoreConfiguration;
//import com.dangdang.ddframe.job.config.dataflow.DataflowJobConfiguration;
//import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
//import com.dangdang.ddframe.job.lite.api.JobScheduler;
//import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
//import com.dangdang.ddframe.job.reg.base.CoordinatorRegistryCenter;
//import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
//import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//import javax.annotation.PostConstruct;
//// 2.x写法
//@Configuration
//public class JobConfig {
//
//    /**
//     * zk注册中心配置
//     *
//     * @return
//     */
//    @Bean
//    public CoordinatorRegistryCenter coordinatorRegistryCenter() {
//        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration("127.0.0.1:2181", "elastic-job-demo"));
//        regCenter.init();
//        return regCenter;
//    }
//
//    // Simple定时任务
//    @Bean(name = "TestSimpleJob")
//    public JobScheduler testSimpleJob(CoordinatorRegistryCenter registryCenter) {
//        // 定义作业核心配置
//        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder("TestSimpleJob1", "0/15 * * * * ?", 3).build();
//        // 定义SIMPLE类型配置
//        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, TestSimpleJob.class.getCanonicalName());
//        // 定义Lite作业根配置
//        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
//        // 启动任务
//        JobScheduler jobScheduler = new JobScheduler(registryCenter, simpleJobRootConfig);
//        jobScheduler.init();
//        System.out.println("TestSimpleJob启动定时任务");
//        return jobScheduler;
//    }
//
//    // DataflowJob
//    @Bean(name = "TestDataflowJob")
//    public JobScheduler testDataflowJob(CoordinatorRegistryCenter registryCenter) {
//        // 定义作业核心配置
//        JobCoreConfiguration coreConfiguration = JobCoreConfiguration
//                .newBuilder("TestDataflowJob", "0/20 * * * * ?", 3)
//                .jobParameter("0=Beijing,1=Shanghai,2=Guangzhou")
//                .build();
//        // 定义DataflowJob类型配置
//        DataflowJobConfiguration jobConfiguration = new DataflowJobConfiguration(coreConfiguration, TestDataflowJob.class.getCanonicalName(),true);
//        // 定义Lite作业根配置
//        LiteJobConfiguration liteJobConfiguration = LiteJobConfiguration.newBuilder(jobConfiguration).build();
//        // 启动任务
//        JobScheduler jobScheduler = new JobScheduler(registryCenter, liteJobConfiguration);
//        jobScheduler.init();
//        System.out.println("DataflowJobConfiguration启动定时任务");
//        return jobScheduler;
//    }
//
//}
